package com.huatai.bi.constant;

/**
 * @BelongsProject: itc-airport-cloud
 * @BelongsPackage: com.huatai.bi.constant
 * @Author: hecaiy
 * @CreateTime: 2024-07-03  09:17
 * @Description: TODO
 * @Version: 1.0
 */
public interface KafkaConstant {

	/**
	 * 数据集加工消息
	 */
	String KAFKA_TOPIC_DATA_SET_PROCESS = "dataSetProcessDB";

	/**
	 * python数据加工操作
	 */
	String KAFKA_TOPIC_DATA_SET_PYTHON = "dataSetPython";

	/**
	 * sql数据集创建数据同步
	 */
	String KAFKA_TOPIC_DATA_SET_SQL = "dataSetSQL";

	String DATA_SET_SYN_TOPIC = "dataSetSynTopic";

	/**
	 * mqtt数据接收处理
	 */
	String MQTT_DATA_ACCEPT="mqtt_data_accept_gh";
	/**
	 * 数据通知执行
	 */
	String DATA_SYN_ACCEPT="datasyntopic";

	/**
	 * 数据项更新
	 */
	String KAFKA_TOPIC_DATA_SET_COLUMN_EDIT = "dataSetClumnEdit";
}
